package mya.mes.mdc.mqtt;


import mya.mes.mdc.share.mqttwrite.MqttClientPublisher;
import mya.mes.mdc.share.mqttwrite.MqttPublishCallback;
import mya.mes.mdc.share.vo.MdcOptions;

public class MqttClientEngine implements MqttClientPublisher {


    private FuseMqttClient fuseMqttClient;

    private MdcOptions mdcOptions;

    public MqttClientEngine(MdcOptions mdcOptions, FuseMqttClient fuseMqttClient) {
        this.fuseMqttClient = fuseMqttClient;
    }

    @Override
    public void publish(String topic, String payload, MqttPublishCallback callback) {
        fuseMqttClient.publish(topic, payload, callback);
    }

}
